package com.wux.labs.integration.kafka.processor;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

@Component
public interface ConsumerProcessor {
    @Input("kafkaChannel2")
    SubscribableChannel subscribableChannel();
}